Page({
  data: {
      sockeTask:'',
      inputValue: ''
  },
  onLoad: function(options) {
    // 页面加载时创建 WebSocket 连接
    this.connectSocket();
  },
  connectSocket: function() {
 var that=this
    this.socketTask = wx.connectSocket({
      url: 'wss://9p47q51245.goho.co/ws',
      success: () => {
        console.log('WebSocket连接成功');
        that.sendSocketMessage('123')
      },
      fail: () => {
        console.log('WebSocket连接失败');
      }
      
    });
    wx.onSocketMessage((message) => {
      console.log('收到服务器内容：' + message.data);
      // 处理接收到的消息
      this.handleReceivedMessage(message.data);
    });
    // 监听WebSocket连接打开事件
    wx.onSocketOpen(() => {
      console.log('WebSocket连接已打开');
    });
  },
  handleReceivedMessage: function(messageData) {
    // 这里是处理服务器端消息的逻辑
    // 通常需要对 messageData 进行解析，如果它是 JSON 格式的话
    try {
      const messageObj = JSON.parse(messageData);
      // 根据消息内容进行相应的处理
      console.log('解析后的消息对象：', messageObj);
      // 可以更新页面数据，显示消息等
    } catch (e) {
      console.error('消息解析失败', e);
    }
  },
  handleInput: function(event) {
    // 处理输入框的输入事件，更新 inputValue
    this.setData({
      inputValue: event.detail.value
    });
  },
  sendSocketMessage: function() {
    // 将数据序列化为JSON字符串
    const messageStr = JSON.stringify({ 'message': this.data.inputValue });

    // 发送数据
    wx.sendSocketMessage({
      data: messageStr,
      success: () => {
        console.log('消息发送成功');
      },
      fail: () => {
        console.log('消息发送失败');
      }
    });
  },
   // 关闭WebSocket连接的方法
   closeSocket: function() {
    if (this.socketTask) {
      this.socketTask.close({
        success: () => {
          console.log('WebSocket连接已关闭');
        },
        fail: () => {
          console.log('WebSocket连接关闭失败');
        }
      });
    }
  },
  
});